package KnowSparkSQL.DSL.DatasetMethods;

import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.SparkSession;

public class DatasetSelectMethods {
    public static void main(String[] args) {
        /**
         * select方法的作用是选择特定列生成新的Dataset<Row>。
         * 它的参数是一个可变参数，类型可以是字符串，也可以是Column
         */

        SparkSession session = SparkSession.builder().appName(DatasetWhereMethods.class.getName()).master("local").getOrCreate();

        Dataset<Row> dataset = session.read().json("./data/student.json");

        dataset.select("name","age").show();
    }
}
